59507381c8c725e28b2978641e638b7c7931f4e9,tests/com/comcast/cmb/test/tools/CQSTestUtils.java,CQSTestUtils,getQueueCount,#String#,49

Before Change



	private static void getQueueCount(String queueUrl) throws NoSuchAlgorithmException, UnsupportedEncodingException {
		int numberOfPartitions = CMBProperties.getInstance().getCQSNumberOfQueuePartitions();
		CassandraPersistence persistence = new CassandraPersistence(CMBProperties.getInstance().getCQSKeyspace());
		String queueHash = Util.hashQueueUrl(queueUrl);
		long messageCount = 0;
		for (int i=0; i<numberOfPartitions; i++) {

After Change



	private static void getQueueCount(String queueUrl) throws NoSuchAlgorithmException, UnsupportedEncodingException {
		int numberOfPartitions = CMBProperties.getInstance().getCQSNumberOfQueuePartitions();
		AbstractCassandraPersistence cassandraHandler = CassandraPersistenceFactory.getInstance(CMBProperties.getInstance().getCQSKeyspace());
		String queueHash = Util.hashQueueUrl(queueUrl);
		long messageCount = 0;
		for (int i=0; i<numberOfPartitions; i++) {